package com.example.toy.core.commit;

import com.example.toy.core.table.TableIdentifier;
import org.apache.hadoop.fs.Path;

/**
 * FsOfflineCommitFactory
 *
 * @author shenbing
 * @date 2021/12/22
 */
public class FsOfflineCommitFactory extends ToyCommitAbstractFactory {

  @Override
  public ToyCommitView getCommitView(TableIdentifier tableIdentifier, Path basePath) {
    return new FsOfflineRealtimeToyCommitView(basePath);
  }

  @Override
  public ToyCommitter getCommitter(TableIdentifier tableIdentifier, Path basePath) {
    return new FsOfflineToyCommitter(basePath);
  }

}
